package com.youzhi.message.kafka;

import java.util.Map;

public interface IKafkaMessageHandler {


    /**
     * 消息处理的类型
     *
     * @return
     */
    String getHandlerType();


    /**
     * 处理消息数据
     *
     * @param data
     */
    void handle(Map<String, Object> data);

}
